package avicit.bdp.dds.dao.entity;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;

/**
 * spark parameters
 */
@ApiModel("spark节点参数配置")
public class SparkConfig {

    /**
     * 集群ID
     */
    @ApiModelProperty("集群ID")
    private String clusterId;


    /**
     * deploy mode：cluster/client
     */
    @ApiModelProperty("部署方式：cluster/client")
    private String deployMode;


    /**
     * driver-cores Number of cores used by the driver, only in cluster mode
     */
    @ApiModelProperty("Driver内核数")
    private Integer driverCores;

    /**
     * driver-memory Memory for driver
     */
    @ApiModelProperty("Driver内存数")
    private String driverMemory;

    /**
     * num-executors Number of executors to launch
     */
    @ApiModelProperty("Executor数量")
    private Integer numExecutors;

    /**
     * executor-cores Number of cores per executor
     */
    @ApiModelProperty("Executor内核数")
    private Integer executorCores;

    /**
     * Memory per executor
     */
    @ApiModelProperty("Executor内存数")
    private String executorMemory;


    /**
     * The YARN queue to submit to
     */
    @ApiModelProperty("YARN queue")
    private String queue;


    /**
     * spark version
     */
    @ApiModelProperty("spark version")
    private String sparkVersion;

    public String getClusterId() {
        return clusterId;
    }

    public void setClusterId(String clusterId) {
        this.clusterId = clusterId;
    }

    public String getDeployMode() {
        return deployMode;
    }

    public void setDeployMode(String deployMode) {
        this.deployMode = deployMode;
    }

    public Integer getDriverCores() {
        return driverCores;
    }

    public void setDriverCores(Integer driverCores) {
        this.driverCores = driverCores;
    }

    public String getDriverMemory() {
        return driverMemory;
    }

    public void setDriverMemory(String driverMemory) {
        this.driverMemory = driverMemory;
    }

    public Integer getNumExecutors() {
        return numExecutors;
    }

    public void setNumExecutors(Integer numExecutors) {
        this.numExecutors = numExecutors;
    }

    public Integer getExecutorCores() {
        return executorCores;
    }

    public void setExecutorCores(int executorCores) {
        this.executorCores = executorCores;
    }

    public String getExecutorMemory() {
        return executorMemory;
    }

    public void setExecutorMemory(String executorMemory) {
        this.executorMemory = executorMemory;
    }

    public String getQueue() {
        return queue;
    }

    public void setQueue(String queue) {
        this.queue = queue;
    }

    public String getSparkVersion() {
        return sparkVersion;
    }

    public void setSparkVersion(String sparkVersion) {
        this.sparkVersion = sparkVersion;
    }
}
